package com.distributer.report.infrastructure.mq;


public class KafkaConfig {

	//@Value("${kafka.consumer.servers}")
	private String bootstrapServers;
	//@Value("${kafka.consumer.auto-offset-reset}")
	private String autoOffsetReset;
	//@Value("${kafka.consumer.max-poll-records}")
	private Integer maxPollRecords;
	//@Value("${kafka.consumer.enable.auto.commit}")
	private String enableAutoCommit;
	//@Value("${kafka.consumer.session-timeout}")
	private long sessionTimeOut;
	//@Value("${kafka.consumer.max-poll-interval}")
	private long maxPollInterval;
	//@Value("${kafka.consumer.max-partition-fech-bytes}")
	private long maxPartitionFetchBytes;
	//@Value("${kafka.consumer.poll-timeout}")
	private long pollTimeOut;

	public String getBootstrapServers() {
		return bootstrapServers;
	}

	public void setBootstrapServers(String bootstrapServers) {
		this.bootstrapServers = bootstrapServers;
	}

	public String getAutoOffsetReset() {
		return autoOffsetReset;
	}

	public void setAutoOffsetReset(String autoOffsetReset) {
		this.autoOffsetReset = autoOffsetReset;
	}

	public Integer getMaxPollRecords() {
		return maxPollRecords;
	}

	public void setMaxPollRecords(Integer maxPollRecords) {
		this.maxPollRecords = maxPollRecords;
	}

	public String isEnableAutoCommit() {
		return enableAutoCommit;
	}

	public void setEnableAutoCommit(String enableAutoCommit) {
		this.enableAutoCommit = enableAutoCommit;
	}

	public long getSessionTimeOut() {
		return sessionTimeOut;
	}

	public void setSessionTimeOut(long sessionTimeOut) {
		this.sessionTimeOut = sessionTimeOut;
	}

	public long getMaxPollInterval() {
		return maxPollInterval;
	}

	public void setMaxPollInterval(long maxPollInterval) {
		this.maxPollInterval = maxPollInterval;
	}

	public long getMaxPartitionFetchBytes() {
		return maxPartitionFetchBytes;
	}

	public void setMaxPartitionFetchBytes(long maxPartitionFetchBytes) {
		this.maxPartitionFetchBytes = maxPartitionFetchBytes;
	}

	public long getPollTimeOut() {
		return pollTimeOut;
	}

	public void setPollTimeOut(long pollTimeOut) {
		this.pollTimeOut = pollTimeOut;
	}

}
